package com.xxwu.messagequeue.common;

import com.xxwu.messagequeue.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * 实现一个函数式接口，用于当消费者调用 basicConsumer 方法时，传入一些参数
 * 通过该方法把消息推送给对应的消费者
 */
public interface Consumer {
    void handleDelivery(String consumerTag, BasicProperties properties, byte[] body) throws IOException, MqException;
}
